package com.cmsr.hdpf.etl

import com.cmsr.hdpf.util.ConfigHelper

trait BaseTask {

  val duration = ConfigHelper.windowDuration // 窗口持续时间
  val timeStep = ConfigHelper.windowTimeStep
  
  def processTask(sourceType: String, sinkType: String, debug: String, windowSize:Int): Unit = {

  }
}